package com.storm.queue.register

import com.storm.queue.model.Job

interface CallBack {
    /**
     * 执行回调接口
     *
     * @param job
     */
    fun execute(job: Job)

    /**
     * 重试超过2次(总共3次)回调接口;
     * 消费者可以在这个方法里面发送钉钉警告邮件警告等等
     * 回调这个接口是一个单独的线程
     *
     * @param t
     */
    fun retryOutTimes(job: Job)

}